package com.bjsxt.config.rocket;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.context.annotation.Configuration;

@Configuration
//@EnableBinding(Source.class)
@EnableBinding({Sink.class, Source.class})// 同时绑定 Sink（接收消息）和 Source（发送消息）
public class RocketMQConfig {
}
